home *** CD-ROM | disk | FTP | other *** search
/ SGI Developer Toolbox 6.1 / SGI Developer Toolbox 6.1 - Disc 4.iso / public / radio / ttytuner.py < prev    next >
Encoding:
Python Source  |  1994-08-02  |  7.4 KB  |  281 lines
  1. #!/usr/local/bin/python
  2.  
  3. # /***********************************************************
  4. # Copyright 1991, 1992, 1993 by Stichting Mathematisch Centrum,
  5. # Amsterdam, The Netherlands.
  6. # 
  7. #                         All Rights Reserved
  8. # 
  9. # Permission to use, copy, modify, and distribute this software and its 
  10. # documentation for any purpose and without fee is hereby granted, 
  11. # provided that the above copyright notice appear in all copies and that
  12. # both that copyright notice and this permission notice appear in 
  13. # supporting documentation, and that the names of Stichting Mathematisch
  14. # Centrum or CWI not be used in advertising or publicity pertaining to
  15. # distribution of the software without specific, written prior permission.
  16. # 
  17. # STICHTING MATHEMATISCH CENTRUM DISCLAIMS ALL WARRANTIES WITH REGARD TO
  18. # THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND
  19. # FITNESS, IN NO EVENT SHALL STICHTING MATHEMATISCH CENTRUM BE LIABLE
  20. # FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  21. # WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  22. # ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT
  23. # OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  24. # 
  25. # ******************************************************************/
  26.  
  27. # A tuner to control radio programs, by Jack Jansen.
  28.  
  29. import sys
  30. import os
  31. import time
  32. import socket
  33. import time
  34. import string
  35. import getopt
  36. from stat import ST_MTIME
  37.  
  38.  
  39. RADIOCTLPORT=54320
  40. TRANSMITTERCTLPORT=54319
  41. CTLWS=socket.gethostname()
  42.  
  43. # The list of networks to broadcast on, when looking for radio
  44. # stations. This should somehow be gotten differently.
  45. #
  46. MCASTLIST = ['192.16.184.0', '192.16.191.0', '192.16.201.255']
  47. # MCASTLIST = ['192.16.201.255']
  48.  
  49. class struct(): pass
  50. info = struct()
  51.  
  52. #
  53. # sendsock - send a message (and get optional reply)
  54. #
  55. def sendsock(host, port, msg, needrepl):
  56.     try:
  57.     host = socket.gethostbyname(host)
  58.     s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  59.     s.sendto(msg, (host,port))
  60.     if needrepl:
  61.         # Loop for max. 2.5 seconds waiting for a reply
  62.         i = 0
  63.         while i < 5 and not s.avail():
  64.         time.millisleep(500)
  65.         i = i + 1
  66.         if not s.avail():
  67.         print 'Radio program not responding'
  68.         return ''
  69.         return s.recv(500)
  70.     except socket.error:
  71.     print 'Incorrect radio settings'
  72.     if needrepl:
  73.         return ''
  74.     else:
  75.         return
  76. #
  77. # sendmulti - send a multicast message (and get replies)
  78. #
  79. def sendmulti(mcastlist, port, msg):
  80.     rv = []
  81.     try:
  82.     s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  83.     s.allowbroadcast(1)
  84.     for host in mcastlist:
  85.         s.sendto(msg, (host,port))
  86.     # Loop for max. 2.5 seconds waiting for a reply
  87.     i = 0
  88.     while i < 25:
  89.         time.millisleep(100)
  90.         i = i + 1
  91.         if s.avail():
  92.         rv.append(s.recv(500))
  93.     except socket.error:
  94.     print 'Incorrect mcast settings'
  95.     return rv
  96. #
  97. # getstationinfo - Return playlist, current and playing time (in minutes).
  98. # Returns a triple (playlist-filename, current record, playing time)
  99. #
  100. def getstationinfo(info):
  101.     name = info[0]
  102.     if len(info) > 3:
  103.     playlist = info[3]
  104.     else:
  105.     playlist = '/ufs/' + name + '/CDlog'
  106.     if len(info) > 5:
  107.     since = eval(info[4])
  108.     cur = string.joinfields(info[5:], ':')
  109.     else:
  110.     curfn = '/ufs/' + name + '/CD'
  111.     try:
  112.         curf = open(curfn,'r')
  113.         cur = curf.readline()
  114.         curf.close()
  115.     except IOError:
  116.         cur = '???'
  117.     if cur[-1:] == '\n':
  118.         cur = cur[:-1]
  119.     try:
  120.         sb = os.stat(curfn)
  121.         since = time.time() - sb[ST_MTIME]
  122.     except os.error:
  123.         since = -1
  124.     if since >= 0: since = since / 60 # Convert to minutes
  125.     if since < 0:
  126.     str = '??'
  127.     elif since < 60:
  128.     str = `since` + ' mins'
  129.     else:
  130.     since = since / 60
  131.     if since < 24:
  132.         str = `since` + ' hrs'
  133.     else:
  134.         str = `since / 24` + ' days'
  135.     return playlist, cur, str
  136.  
  137. #
  138. # updateinfo - Update one of the views with info on station 'name'
  139. #
  140. def printinfo(info):
  141.     name = info[0]
  142.     print 'Station '+ name + ':'
  143.     print '\tPort               ' + `info[1]`
  144.     if name == '' or name[:3] == '???':
  145.     print '\tNo information on station'
  146.     else:
  147.     try:
  148.         p, c, t = getstationinfo(info)
  149.     except IOError:
  150.         return
  151.     if c <> '' and c <> '???':
  152.         print '\tCurrently playing: ' + c
  153.     if t <> '??':
  154.         print '\tSince:             ' + t
  155.     if p <> '':
  156.         print '\tPlaylist in file:  ' + p
  157.  
  158. #
  159. # getstations - Return an array of (stationname, stationport)
  160. # listing all available stations.
  161. #
  162. def getstations():
  163.     stations = []
  164.     raw = sendmulti(MCASTLIST, TRANSMITTERCTLPORT, 'radio:s')
  165.     for i in raw:
  166.     if i[:7] == 'radio:S':
  167.         fields = string.splitfields(i,':')[2:]
  168.         fields[1] = string.atoi(fields[1])
  169.         stations.append(fields)
  170.     else:
  171.         print 'Funny reply from transmitter:', i[:7]
  172.     return stations
  173.  
  174. #
  175. # getcurstation - Return (name,port) for station to which radio
  176. # on workstation ws is currently tuned to.
  177. #
  178. def getcurstation(stationlist, ws, port):
  179.     rv = sendsock(ws, port, 'radio:i', 1)
  180.     if rv == '':
  181.     return ('',0)
  182.     if rv[0:8] <> 'radio:I:':
  183.     print 'Illegal reply from radio:',rv
  184.     return ('',0)
  185.     # Remove optional pause field
  186.     rv = rv[8:]
  187.     rv = string.splitfields(rv,':')
  188.     if len(rv) == 1:            # Old: port
  189.     tport = string.atoi(rv[0])
  190.     playing = 1
  191.     elif len(rv) == 2:            # newer: playing, port
  192.     tport = string.atoi(rv[1])
  193.     playing = string.atoi(rv[0])
  194.     elif len(rv) == 3:            # Still newer: playing, port, version
  195.     tport = string.atoi(rv[1])
  196.     playing = string.atoi(rv[0])
  197.     else:                # Too new
  198.     print 'Unknown reply to info: ', rv
  199.     for i in stationlist:
  200.     if i[1] == tport:
  201.         return (i, playing)
  202.     return (('???(port '+`tport`+')' ,tport), playing)
  203.  
  204. def main():
  205.     radio_port = RADIOCTLPORT
  206.     radio_ws = CTLWS
  207.     try:
  208.     optlist, args = getopt.getopt(sys.argv[1:], 'w:p:lLcPCT')
  209.     mode = ''
  210.     for o, a in optlist:
  211.         if o == '-w':
  212.         radio_ws = a
  213.         elif o == '-p':
  214.         radio_port = string.atoi(a)
  215.         elif mode == '':
  216.         mode = o[1]
  217.         else:
  218.         raise getopt.error
  219.     if len(args) + len(mode) <> 1:
  220.         raise getopt.error
  221.     except getopt.error:
  222.     print 'Usage: '+sys.argv[0]+' [options] command'
  223.     print 'Options:'
  224.     print '\t-w ws\tControl radio on workstation ws'
  225.     print '\t-p port\tControl radio on port port'
  226.     print 'Command:'
  227.     print '\t-l\tList names of active stations'
  228.     print '\t-L\tList names and info of active stations'
  229.     print '\t-c\tList info on current station'
  230.     print '\t-P\tTemporarily suspend radio, freeing port'
  231.     print '\t-C\tContinue radio'
  232.     print '\t-T\tToggle suspend/continue'
  233.     print '\tstation\tTune to new station'
  234.     sys.exit(1)
  235.     
  236.     #
  237.     # First, do pause/continue command.
  238.     #
  239.     if mode == 'P':
  240.     sendsock(radio_ws, radio_port, 'radio:0', 0)
  241.     sys.exit(0)
  242.     if mode == 'C':
  243.     sendsock(radio_ws, radio_port, 'radio:1', 0)
  244.     sys.exit(0)
  245.     if mode == 'T':
  246.     cn, playing = getcurstation([], radio_ws, radio_port)
  247.     sendsock(radio_ws, radio_port, 'radio:'+`not playing`, 0)
  248.     sys.exit(0)
  249.     #
  250.     # And list of new stations
  251.     #
  252.     stations = getstations()
  253.     #
  254.     # Set info for current station
  255.     #
  256.     if mode == '' or mode == 'c':
  257.     cn, playing = getcurstation(stations,radio_ws, radio_port)
  258.     if mode == 'l':
  259.     for i in stations:
  260.         print i[0]
  261.     elif mode == 'L':
  262.     for i in stations:
  263.         printinfo(i)
  264.     elif mode == 'c':
  265.     printinfo(cn)
  266.     else:
  267.     for i in range(len(stations)):
  268.         if stations[i][0] == args[0]:
  269.         sendsock(radio_ws, radio_port, \
  270.                 'radio:t:' + `stations[i][1]`, 0)
  271.         sys.exit(0)
  272.     print 'No such station: ', args[0]
  273.     
  274.     
  275.  
  276. main()
  277.  
  278. # Local variables:
  279. # py-indent-offset: 4
  280. # end:
  281.